package com.ymm.system.core.config.mq;

import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;
import org.apache.rocketmq.remoting.common.RemotingHelper;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * @Author zikang.yao
 * @Description TODO
 * @Date 2022/8/9 16:58
 * @Version 1.0
 */
//@Component
//public class Producer {
//    @Autowired
//    private RocketMQTemplate rocketMQTemplate;
////    @Autowired
////    private
//
//    public void sendMessage(String topic,Object msg){
//        rocketMQTemplate.convertAndSend(topic,msg);
//    }
//
//}

